#coding:utf8
from celery import Celery
import os

# tasks --> broker -->  worker

# 1. celery是一个即插即用的 异步任务，celery运行的时候需要使用到django的setting文件
# 所以我们需要在 celery运行的时候 去配置一下

#第一种方式
# os.environ.setdefault("DJANGO_SETTINGS_MODULE", "mall.settings")

#第二种方式
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'mall.settings'




#.2.我们需要创建celery对象
# 第一个参数： main
# 习惯上 设置 脚本名
app = Celery('celery_tasks')


# 3. 设置中间人 broker
# 路径
app.config_from_object('celery_tasks.config')


# 4. celery自动检测任务
# 列表中的元素 就是 任务的包路径
app.autodiscover_tasks(['celery_tasks.sms','celery_tasks.html'])


# 5. worker
# 我们的worker其实是一条指令，这条指令需要在 虚拟环境中执行

#
#celery -A 文件路径.celery实例对象文件  worker -l info
#celery -A celery_tasks.main  worker -l info
